72551def07b123598cd739ab474ac2844ae9daea,presto-main/src/main/java/com/facebook/presto/sql/planner/LocalExecutionPlanner.java,Visitor,createNestedLoopJoin,#JoinNode#LocalExecutionPlanContext#,1470
Before Change
buildSource.getTypes());
checkArgument(buildContext.getDriverInstanceCount().orElse(1) == 1, "Expected local execution to not be parallel");
context.addDriverFactory(new DriverFactory(
buildContext.isInputDriver(),
false,
ImmutableList.<OperatorFactory>builder()
.addAll(buildSource.getOperatorFactories())
.add(nestedLoopBuildOperatorFactory)
.build(),
buildContext.getDriverInstanceCount()));
NestedLoopJoinPagesSupplier nestedLoopJoinPagesSupplier = nestedLoopBuildOperatorFactory.getNestedLoopJoinPagesSupplier();
ImmutableMap.Builder<Symbol, Integer> outputMappings = ImmutableMap.builder();
After Change
checkArgument(buildContext.getDriverInstanceCount().orElse(1) == 1, "Expected local execution to not be parallel");
context.addDriverFactory(
buildContext.isInputDriver(),
false,
ImmutableList.<OperatorFactory>builder()
.addAll(buildSource.getOperatorFactories())
.add(nestedLoopBuildOperatorFactory)
.build(),
buildContext.getDriverInstanceCount());
NestedLoopJoinPagesSupplier nestedLoopJoinPagesSupplier = nestedLoopBuildOperatorFactory.getNestedLoopJoinPagesSupplier();
ImmutableMap.Builder<Symbol, Integer> outputMappings = ImmutableMap.builder();